package com.dataflow.example.interceptor;

import com.etl.dataflow.common.entity.TaskParam;
import com.etl.dataflow.executor.core.AbstractTaskLaunchInterceptor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Scope;
import org.springframework.stereotype.Component;

@Slf4j
@Component("MyTaskLaunchInterceptor")
@Scope("prototype")
public class MyTaskLaunchInterceptor extends AbstractTaskLaunchInterceptor {
    @Override
    public TaskParam beforeLaunch(TaskParam taskParam) {
        log.debug(">>>>>>>>>>>>>>>>>>任务启动拦截器已执行，任务参数：" + taskParam);
        return null;
    }
}
